# 示例 5: 线程间通信（使用队列）
"""
在这个示例中，我们使用了一个队列来在生产者线程和消费者线程之间进行通信。
生产者将项目放入队列中，而消费者从队列中取出项目进行处理。当生产者完成
生产后，它发送一个None作为结束信号给消费者，消费者收到信号后停止处理。
"""
import threading
import queue
import time

def producer(q):
    for i in range(5):
        item = "item-{}".format(i)
        q.put(item)
        print("Produced {}".format(item))

def consumer(q):
    while True:
        item = q.get()
        # time.sleep(1)
        if item is None:# 使用None作为结束信号
            break
        print("Consumed {}".format(item))
        q.task_done()

q = queue.Queue()

producer_thread = threading.Thread(target=producer, args=(q,))
consumer_thread = threading.Thread(target=consumer, args=(q,))

producer_thread.start()
consumer_thread.start()

producer_thread.join()
q.put("None") # 发送结束信号给消费者
consumer_thread.join()

print("All items have been produced and consumed.")























